#!/usr/bin/env python
import pika

exchange = "111111111"
queue = "111111111-start"

connection = pika.BlockingConnection(pika.ConnectionParameters('172.16.8.24'))
channel = connection.channel()
channel.queue_declare(queue=queue)
channel.basic_publish(exchange='',
                      routing_key=queue,
                      body='start now!')
print(" [x] Sent 'start!'")
connection.close()
